import org.leiyang.common.util.ByteUtils;
import reactor.core.publisher.Mono;

import java.time.Duration;
import java.util.Objects;

public class webflux {

    public static void main(String[] args) {
//        Mono<Duration> expire = Mono.just(Duration.ZERO);
//        expire.subscribe(duration -> {
//            //表示没有设置过期时间
//            if(Objects.isNull(duration) || Objects.equals(duration, Duration.ZERO)) {
//                System.out.println("执行了");
//            }
//        });

//        Mono<Boolean> c = Mono.just(false);
//        c.map(data -> {
//            if(data) {
//                return "right";
//            }
//            return "";
//        }).subscribe(System.out::println);

        System.out.println(ByteUtils.convertFromByte((byte) 1));
    }
}
